package bean.dao;

import hbt.HibernateUtil;

import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;

import javax.persistence.NamedQuery;



import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.hibernate.transform.Transformers;

import app.dto.DetalleItemDto;

import dominio.Rodamiento;
import exceptions.InsertException;
import exceptions.ModifyException;

public class HibernateRodamientoDAO {

	private static HibernateRodamientoDAO instancia = null;
	private static SessionFactory sf = null;
	private Session session = null;

	public static HibernateRodamientoDAO getInstancia() {
		if (instancia == null) {
			sf = HibernateUtil.getSessionFactory();
			instancia = new HibernateRodamientoDAO();
		}
		return instancia;
	}

	private Session getSession() {
		if (session == null)
			session = sf.openSession();
		return session;
	}

	public void closeSession() {
		if (session != null)
			session.close();
	}

	public List<Rodamiento> getListaRodamientos(String sufijo, String marca,
			String nroSerie, String origen, int cant, String carac) {
		
		
		origen = origen == "-Todos-"? "": origen;
		
		String query = "select r from Rodamiento r where r.numeroSerie like '%"+nroSerie+ "%' and r.marca like '%"+marca+"%' and r.sufijo like '%"+sufijo+"%' and (r.caracteristica like '%"+carac+"%' or ( r.caracteristica is null and '"+carac+"' = '' )) and r.origen like '%"+origen+"%'";
		
		Session s = getSession();
		List<Rodamiento> rodamientos = (List<Rodamiento>)s.createQuery(query).list();
		
		System.out.println("Cantidad de registros:" + rodamientos.size());
		return rodamientos;
	}

	/*********************************************
	 * AMB DE RODAMIENTOS
	 * 
	 * @throws InsertException
	 **********************************************************/

	public void agregarRodamiento(Rodamiento r) throws InsertException {
		try {
			Session s = getSession();
			s.beginTransaction();
			s.persist(r);
			s.flush();
			s.getTransaction().commit();
		} catch (Exception e) {
			session = null;
			throw new InsertException("Rodamiento");
		}

	}

	public boolean mismoRodamiento(String numeroSerie, String sufijo,
			String marca, String origen) {

		Session s = getSession();
		Rodamiento r = (Rodamiento) s.getNamedQuery("mismoRodamiento")
				.setString("ns", numeroSerie).setString("s", sufijo)
				.setString("m", marca).setString("o", origen).uniqueResult();
		if (r == null)
			return false;
		else
			return true;

	}

	public Rodamiento getMismoRodamiento(String numeroSerie, String sufijo,
			String marca, String origen) {

		Session s = getSession();
		Rodamiento r = (Rodamiento) s.getNamedQuery("mismoRodamiento")
				.setString("ns", numeroSerie).setString("s", sufijo)
				.setString("m", marca).setString("o", origen).uniqueResult();
		return r;
	}

	public int ultimoIdRodamiento() {
		Session s = getSession();
		int i = (Integer) s.createQuery(
				"select max(r.idRodamiento) from Rodamiento r").uniqueResult();
		return i;
	}

	@SuppressWarnings("unchecked")
	public List<Integer> rodamientosId() {

		Session s = getSession();
		List<Integer> lista = s.createQuery(
				"select r.idRodamiento from Rodamiento r").list();
		return lista;
	}

	public Rodamiento getRodamiento(int id) {
		Session s = getSession();
		Rodamiento r = (Rodamiento) s.createQuery(
				"select r from Rodamiento r where r.idRodamiento=" + id)
				.uniqueResult();
		s.clear();
		return r;
	}

	public void eliminarRodamiento(int id) {

		Session s = getSession();
		Rodamiento r = (Rodamiento) s.createQuery(
				"select r from Rodamiento r where idRodamiento=" + id)
				.uniqueResult();
		s.beginTransaction();
		s.delete(r);
		s.flush();
		s.getTransaction().commit();
		s.clear();
	}

	public void modificarRodamiento(int id, String ns, String s, String m,
			String o, String c, float p, int cant) throws ModifyException {
		try {
			Session se = getSession();
			se.beginTransaction();

			Rodamiento r = new Rodamiento();
			r.setIdRodamiento(id);
			r.setNumeroSerie(ns);
			r.setSufijo(s);
			r.setMarca(m);
			r.setOrigen(o);
			r.setPrecio(p);
			r.setStock(cant);
			r.setCaracteristica(c);
			se.update(r);
			se.flush();
			se.getTransaction().commit();
			se.clear();
		} catch (Exception e) {
			session = null;
			throw new ModifyException("Rodamiento");
		}
	}
	
	public void modificarRodamiento(Rodamiento r) throws ModifyException {
		try {
			Session se = getSession();
			se.beginTransaction();
			se.update(r);
			se.flush();
			se.getTransaction().commit();
			se.clear();
		} catch (Exception e) {
			session = null;
			throw new ModifyException("Rodamiento");
		}
	}

	@SuppressWarnings("unchecked")
	public List<DetalleItemDto> obtenerMejoresPrecios(String marca,
			String carac, String origen, String sufijo, String nroSerie, boolean todos) 
			
			{
		
				String query = "select r.sufijo as sufijo, r.marca as marca, r.origen as origen, r.caracteristica as caracteristica, cast(r.numeroSerie as string) as serie, p.razonSocial as proveedor, cast(lp.numeroLista as string) as numeroLista, min(it.precio) as precio "+
				"from ItemListaPrecios it "+
				"inner join it.rodamiento r "+
				"inner join it.listaPrecios lp "+
				"inner join lp.proveedor p "+
				"where r.numeroSerie like '%"+nroSerie+ "%' and r.marca like '%"+marca+"%' and r.sufijo like '%"+sufijo+"%' and (r.caracteristica like '%"+carac+"%' or ( r.caracteristica is null and '"+carac+"' = '' )) and r.origen like '%"+origen+"%' "+
				"group by r.sufijo, r.marca, r.origen, r.numeroSerie, r.caracteristica, p.razonSocial, lp.numeroLista" ;				
				Session s = getSession();
				List<DetalleItemDto> items =  s.createQuery(query).setResultTransformer(Transformers.aliasToBean(DetalleItemDto.class)).list();
						
				System.out.println("Cantidad de registros:" + items.size());
				return items;
			}
	}


